package com.atguigu.qz.controll

import com.atguigu.qz.service.DwsQzService
import com.atguigu.util.{BaseControll, HiveUtil}
import org.apache.spark.sql.SparkSession

/**
 * description ：做题模块指标统计
 * author      ：剧情再美终是戏 
 * mail        : 13286520398@163.com
 * date        ：Created in 2020/3/8 14:38
 * modified By ：
 * version:    : 1.0
 */
object AdsQzControll extends BaseControll {
  override def initAppName(appName: String) = super.initAppName(this.getClass.getName)

  override def doSmething(spark: SparkSession, dt: String, dn: String) = {
    // 开启动态分区
    HiveUtil.openDynamicPartition(spark)

    // 使用 sql 查询指标
    DwsQzService.queryDetailBysql(spark, dt, dn)

    // 使用 api 查询指标
    DwsQzService.queryDetailByApi(spark, dt, dn)
  }
}
